package com.lmn.stream.rocketmq;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

public interface Sink {

    @Input(MyTopic.LOGIN)
    SubscribableChannel login();


}
